package cn.felord.debezium.mina;

import cn.felord.debezium.service.TcpActService;
import lombok.extern.slf4j.Slf4j;
import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;
import org.springframework.stereotype.Component;

import java.io.IOException;

@Component
@Slf4j
/**
 * 接收重量
 */
public class TimeServerHandler extends IoHandlerAdapter {

    private TcpActService tcpActService;

    public TimeServerHandler(TcpActService tcpActService) {
        this.tcpActService = tcpActService;
    }
    @Override
    public void messageReceived(IoSession session, Object message) throws IOException {
        String mes = message.toString();
//        log.info("yyy 收到:" + mes);

    }
}

